package com.shujia.spark.sql

import org.apache.spark.SparkContext
import org.apache.spark.sql.SparkSession

object Demo01Session {
  def main(args: Array[String]): Unit = {

    // SparkSession：从Spark2.0开始引入的新入口
    val spark: SparkSession = SparkSession
      .builder()
      .appName(this.getClass.getSimpleName.replace("$", ""))
      .master("local") // 设置运行的方式
      .config("spark.default.parallelism", "2")
      .getOrCreate()

    // SparkSession中内置了sc
    val sc: SparkContext = spark.sparkContext



  }

}
